<?php
$tempEmailList = [
    '176927050@qq.com',
    '276927050@qq.com',
    '376927050@qq.com',
    '476927050@qq.com',
    '576927050@qq.com',
    '676927050@qq.com',
    '776927050@qq.com'
];

function sendMail($email){
    sleep(2);
    //echo $email . '发送成功';
}

// 把要处理的邮箱地址列表 存放到redis的队列里
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
foreach($tempEmailList as $email){
	$redis->lpush('wait_handle_email_list',$email);
}

// 连接tcp服务器 告诉它 去处理队列里面的邮件列表
$client = new swoole_client(SWOOLE_SOCK_TCP);
if( !$client->connect("127.0.0.1", 9501 , 1) ) {
    echo "Error: {$this->client->errMsg}[{$this->client->errCode}]\n";
}

// 客户端给服务端发请求处理 指令
$action = 'sendMailQueue';
$time = time();
$key = 'MYgGnQE33ytd2jDFADS39DSEWsdD24sK';  // 客户端的标示
$token = md5($action.$time.$key);  // 做了一个安全签名 为了防止有人抓取我们的请求 篡改我们请求数据
$data = [
	'action' => $action,
	'token' => $token,
	'timestamp' => $time
];
$msg = json_encode($data);  // json处理
$client->send( $msg ); // 发送给tcp服务器



header('content-type:application/json;charset=utf-8');
echo json_encode(['code'=>1,'message'=>'邮件列表已经在处理...']);